f1e3931bd70fe430150bf4d17a31764bab6d0cd3,hazelcast/src/main/java/com/hazelcast/collection/multimap/tx/TransactionalMultiMapProxySupport.java,TransactionalMultiMapProxySupport,removeInternal,#Data#Data#,103
Before Change
}
if (version != -1 || recordId != -1){
TxnRemoveOperation operation = new TxnRemoveOperation(proxyId, key, recordId, value);
MultiMapTransactionLog log = (MultiMapTransactionLog)tx.getTransactionLog(getTxLogKey(key));
if (log != null){
log.addOperation(operation);
}
else {
log = new MultiMapTransactionLog(key, proxyId, ttl, getThreadId(), version, operation);
After Change
coll = createCollection(response.getRecordCollection(getNodeEngine()));
txMap.put(key, coll);
} else {
log = (MultiMapTransactionLog)tx.getTransactionLog(getTxLogKey(key));
}
CollectionRecord record = new CollectionRecord(config.isBinary() ? value : getNodeEngine().toObject(value));
Iterator<CollectionRecord> iterator = coll.iterator();
long recordId = -1;
while (iterator.hasNext()){
CollectionRecord r = iterator.next();
if (r.equals(record)){
iterator.remove();
recordId = r.getRecordId();
break;
}
}
if (version != -1 || recordId != -1){
TxnRemoveOperation operation = new TxnRemoveOperation(proxyId, key, recordId, value);
log.addOperation(operation);
return recordId != -1;
}
return false;